fe3d21427c475580f79dbcf4359629ffbccccd6f,kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ReplicaSetOperationsImpl.java,ReplicaSetOperationsImpl,waitUntilReady,#number#TimeUnit#,256

Before Change


      return rs;
    }

    final CountDownLatch latch = new CountDownLatch(1);
    Watcher<ReplicaSet> watcher = new ReadinessWatcher<>(latch);
    try (Watch watch = watch(watcher)) {
      if (latch.await(amount, timeUnit)) {
        return get();
      }
    }
    throw new KubernetesClientTimeoutException(rs.getKind(), getName(), getNamespace(), amount, timeUnit);
  }

  private static class ReplicaSetReaper implements Reaper {

After Change


      return rs;
    }

    ReadinessWatcher<ReplicaSet> watcher = new ReadinessWatcher<>(rs.getKind(), getName(), getNamespace());
    try (Watch watch = watch(watcher)) {
      return watcher.await(amount, timeUnit);
    }
  }